package com.ftqh.tutorial.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;

/**
 * SinkReceiver class
 *
 * @author john zhang
 * @date 2017/11/1
 */
@EnableBinding(Sink.class)
@Slf4j
public class SinkReceiver {
    @StreamListener(Sink.INPUT)
    public void receive(Object payload){
        log.info("Received:"+payload);
    }

}
